package com.example.demo.services.listion;


import com.example.demo.entity.testRedis;
import com.example.demo.utils.RedisUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class rabbitmqService {

    private Logger logger= LoggerFactory.getLogger(getClass());

    @Autowired
    private RedisUtil redisUtil;


    /**
     * 可以在监听事件中加入逻辑语法 操作数据库或redis 或者返回信息，封装信息
     * @param testRedis
     */
    @RabbitListener(queues = "userlogin")
    public void userListion(testRedis testRedis){
        logger.info("监听rabbitmq信息",testRedis);
        System.out.println(testRedis);
        //时间控制台打出来的应该是 序列化的 到时候写进redis里面我的配置文件会自动转成正常的时间格式
        redisUtil.set("rabbitmqceshi",testRedis);
    }

}
